fc38d54bcbd5fb49263b80af7706598991fc52a5,core/java/src/net/i2p/internal/QueuedI2CPMessageReader.java,QueuedI2CPMessageReaderRunner,run,#,38

Before Change


                        if (msg.getType() == PoisonI2CPMessage.MESSAGE_TYPE)
                            cancelRunner();
                        else
                            _listener.messageReceived(QueuedI2CPMessageReader.this, msg);
                    } catch (InterruptedException ie) {}
                }
                // ??? unused

After Change


                            _listener.disconnected(QueuedI2CPMessageReader.this);
                            cancelRunner();
                        } else {
                            _listener.messageReceived(QueuedI2CPMessageReader.this, msg);
                        }
                    } catch (InterruptedException ie) {}
                }